package com.dubbo.lian.cms.modules.app.mq.queue;
 import com.dubbo.lian.cms.modules.app.mq.PersonInfo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.stereotype.Component;
 import javax.jms.Queue;
 /**
 * 点对点消息生产者
 * 
 * 作者: zhoubang 
 * 日期：2015年9月28日 上午10:07:56
 */
@Component
public class QueueMessageProducer {
     @Autowired
    private JmsTemplate jmsTemplate;
     @Autowired
    private Queue defaultDestination;
     public void sendQueueMessage(PersonInfo personInfo) {
         getJmsTemplate().convertAndSend(this.defaultDestination, personInfo);
    }
     public void sendQueueMessage(Object obj) {
         System.out.println("QueueMessageProducer 消息生产者开始发送消息...");
         getJmsTemplate().convertAndSend(this.defaultDestination, obj);
    }
     public JmsTemplate getJmsTemplate() {
        return jmsTemplate;
    }
     public void setJmsTemplate(JmsTemplate jmsTemplate) {
        this.jmsTemplate = jmsTemplate;
    }
     public Queue getDefaultDestination() {
        return defaultDestination;
    }
     public void setDefaultDestination(Queue defaultDestination) {
        this.defaultDestination = defaultDestination;
    }
 }
